#include "app_mqtt.h"
#include "log/log.h"
#include <unistd.h>

int recv_callback(char *data, int len)
{
    log_debug("recv_callback, data:%s, len:%d", data, len);
    return 0; // 成功处理一定返回0 =》 否则会导致程序错误结束
}

int main(int argc, char const *argv[])
{
    app_mqtt_init();

    app_mqtt_registerRecvCallback(recv_callback);

    app_mqtt_sendMsg("abcd", 4);
    log_debug("程序即将休眠10s");
    sleep(5); // 休眠50秒
    log_debug("程序即将退出");

    app_mqtt_close();

    return 0;
}
